set table.dynamic-table-options.enabled = true;

-- source
CREATE TABLE hdp_lbg_supin_ods_tsar_detail (
    content string
)
with(
'connector' = 'kafka',
'topic' = 'tsar_detail',
'properties.bootstrap.servers' = 'node101:9092',
'properties.group.id' = 'hdp_lbg_supin_group1',
'properties.client.id' = 'hdp_lbg_supin_group1-FRZfA',
'scan.startup.mode' = 'group-offsets',
'sink.parallelism' = '1',
'format' = 'raw'
);

CREATE TABLE hdp_lbg_supin_ods_tsar_detail2 (
    content string
)
with(
'connector' = 'kafka',
'topic' = 'tsar_detail',
'properties.bootstrap.servers' = 'node101:9092',
'properties.group.id' = 'hdp_lbg_supin_group1',
'properties.client.id' = 'hdp_lbg_supin_group1-FRZfA',
'scan.startup.mode' = 'group-offsets',
'sink.parallelism' = '1',
'format' = 'raw'
);

insert into hdp_lbg_supin_ods_tsar_detail2
select content
from hdp_lbg_supin_ods_tsar_detail;
